//package com.iclient.dao.task;
//
//import java.util.List;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Repository;
//import org.springframework.util.CollectionUtils;
//
//import com.alibaba.fastjson.JSONObject;
//import com.iclient.dao.model.SinaWbUser;
//import com.iclient.dao.service.SinaWbUserService;
//import com.plugins.server.MQServer;
//
//@Repository
//public class SinaTask {
//	
//	@Autowired
//	private SinaWbUserService sinaWbUserService;
//	
//	@Scheduled(cron="0 0/1 * * * ?")
//	public void executeTaskJob(){
//		MQServer mqServer = MQServer.getServer();
//		List<SinaWbUser> users = sinaWbUserService.findUnFollowUsers();
//		if(!CollectionUtils.isEmpty(users)){
//			for(SinaWbUser sinaWbUser : users){
//				mqServer.publishMsg("go", "followuser", "follow:user", JSONObject.toJSONString(sinaWbUser));
//			}
//		}
//	}
//
//}
